package com.yy.job.boot.service.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import com.yy.job.core.domain.JobResult;
import com.yy.job.core.domain.JobStepDomain;
import com.yy.job.core.run.process.IJobStepProcess;

@Service("jobTask3")
public class JobTask3 implements IJobStepProcess {
	
	private Logger logger = LoggerFactory.getLogger(this.getClass());
	
	public JobResult execute(JobStepDomain paramJobTask, String paramT) {
		logger.info("I am in jobTask3, param={}", paramT);
		
		String message = String.format("I am error, id=%s, stepId=%s", paramJobTask.getJobId(), paramJobTask.getId());
		throw new RuntimeException(message);

		//return JobResult.fail("我错了", "内存溢出");
	}

}
